package org.util.concurrent;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * @author liangsu
 * @version v1.0
 * @Description
 * @Date 2020/11/6 9:40
 * @since
 */
public interface BindThreadQueueFactory {

    BlockingQueue<Runnable> newQueue();

    BindThreadQueueFactory DEFAULT = new BindThreadQueueFactory() {
        @Override
        public BlockingQueue<Runnable> newQueue() {
            return new LinkedBlockingQueue<>();
        }
    };
}
